package io.netty.example.fep.netty;

import io.netty.example.fep.netty.client.ClientHandler;
import io.netty.example.fep.netty.common.FepProtocolMsg;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * Description：
 * 客户端自定义消息处理器
 *
 * @author : chenjie03@imdada.cn
 * Date: 2020/5/27
 * Time: 13:33
 */
public class MyClientHandler implements ClientHandler {

    private Logger logger = LoggerFactory.getLogger(this.getClass());

    public static MyClientHandler INSTANCE = new MyClientHandler();

    private MyClientHandler() {
    }


    /**
     * 服务端-心跳处理器
     *
     * @param message 消息体
     */
    @Override
    public void activeHandler(FepProtocolMsg message) {
        logger.info("==========服务端已收到注册心跳==========");
    }

    /**
     * 服务端-远程查询处理器
     *
     * @param message 消息体
     */
    @Override
    public void queryHandler(FepProtocolMsg message) {
        logger.info("==========开始查询数据库==========");
    }

    /**
     * 服务端-其他消息处理器
     *
     * @param message 消息体
     */
    @Override
    public void otherHandler(FepProtocolMsg message) {

    }
}
